package cn.gwm.flink.streaming.sink.kafka;

/**
 * @ClassName KafkaConsumerEnum
 * @Description
 * @Author LiangGuang
 * @Date 2023/06/14 14:07
 */
public enum KafkaConsumerEnum {
    /**
     * 最早位置
     */
    EARLIEST,
    /**
     * 最新位置
     */
    LATEST,
    /**
     * 消费者组最新位置
     */
    GROUPOFFSETS,
    /**
     * 指定时间戳位置
     */
    TIMESTAMP
}
